🎖️GitЯра🎖️ - /page/blob.mu

T8b949e/*

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787co.touchlab.kermit.Severity

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787kotlinx.coroutines.Job

Tff7b72import T7ee787kotlinx.coroutines.flow.first

Tff7b72import T7ee787kotlinx.coroutines.launch

Tff7b72import T7ee787okio.ByteString

Tff7b72import T7ee787org.koin.core.annotation.Named

Tff7b72import T7ee787org.koin.core.annotation.Single

Tff7b72import T7ee787org.meshtastic.core.common.util.handledLaunch

Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis

Tff7b72import T7ee787org.meshtastic.core.common.util.nowSeconds

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.MessageStatus

Tff7b72import T7ee787org.meshtastic.core.model.Node

Tff7b72import T7ee787org.meshtastic.core.model.Reaction

Tff7b72import T7ee787org.meshtastic.core.model.util.MeshDataMapper

Tff7b72import T7ee787org.meshtastic.core.model.util.decodeOrNull

Tff7b72import T7ee787org.meshtastic.core.model.util.toOneLiner

Tff7b72import T7ee787org.meshtastic.core.repository.AdminPacketHandler

Tff7b72import T7ee787org.meshtastic.core.repository.DataPair

Tff7b72import T7ee787org.meshtastic.core.repository.MeshDataHandler

Tff7b72import T7ee787org.meshtastic.core.repository.MeshServiceNotifications

Tff7b72import T7ee787org.meshtastic.core.repository.MessageFilter

Tff7b72import T7ee787org.meshtastic.core.repository.NeighborInfoHandler

Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager

Tff7b72import T7ee787org.meshtastic.core.repository.Notification

Tff7b72import T7ee787org.meshtastic.core.repository.NotificationManager

Tff7b72import T7ee787org.meshtastic.core.repository.PacketHandler

Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository

Tff7b72import T7ee787org.meshtastic.core.repository.PlatformAnalytics

Tff7b72import T7ee787org.meshtastic.core.repository.RadioConfigRepository

Tff7b72import T7ee787org.meshtastic.core.repository.ServiceBroadcasts

Tff7b72import T7ee787org.meshtastic.core.repository.ServiceRepository

Tff7b72import T7ee787org.meshtastic.core.repository.StoreForwardPacketHandler

Tff7b72import T7ee787org.meshtastic.core.repository.TelemetryPacketHandler

Tff7b72import T7ee787org.meshtastic.core.repository.TracerouteHandler

Tff7b72import T7ee787org.meshtastic.core.resources.Res

Tff7b72import T7ee787org.meshtastic.core.resources.critical_alert

Tff7b72import T7ee787org.meshtastic.core.resources.error_duty_cycle

Tff7b72import T7ee787org.meshtastic.core.resources.getStringSuspend

Tff7b72import T7ee787org.meshtastic.core.resources.unknown_username

Tff7b72import T7ee787org.meshtastic.core.resources.waypoint_received

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.Paxcount

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787org.meshtastic.proto.Position

Tff7b72import T7ee787org.meshtastic.proto.Routing

Tff7b72import T7ee787org.meshtastic.proto.StatusMessage

Tff7b72import T7ee787org.meshtastic.proto.User

Tff7b72import T7ee787org.meshtastic.proto.Waypoint

T8b949e/**

* Implementation of [MeshDataHandler] that decodes and routes incoming mesh data packets.

*

* This class handles the complexity of:

* 1. Mapping raw [MeshPacket] objects to domain-friendly [DataPacket] objects.

* 2. Routing packets to specialized handlers (e.g., Traceroute, NeighborInfo, Telemetry, Admin, SFPP).

* 3. Managing message history and persistence.

* 4. Triggering notifications for various packet types (Text, Waypoints).

*/

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongParameterListTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffCyclomaticComplexMethodTa5d6ff"Tb4b4b4)

Tf0883e@Single

Tff7b72class T56d364MeshDataHandlerImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3packetHandlerTb4b4b4: Te6edf3PacketHandlerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3serviceRepositoryTb4b4b4: Te6edf3ServiceRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3packetRepositoryTb4b4b4: Te6edf3LazyTff7b72<Te6edf3PacketRepositoryTff7b72>Tb4b4b4,

Tff7b72private Tff7b72val Te6edf3serviceBroadcastsTb4b4b4: Te6edf3ServiceBroadcastsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3notificationManagerTb4b4b4: Te6edf3NotificationManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3serviceNotificationsTb4b4b4: Te6edf3MeshServiceNotificationsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3analyticsTb4b4b4: Te6edf3PlatformAnalyticsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3dataMapperTb4b4b4: Te6edf3MeshDataMapperTb4b4b4,

Tff7b72private Tff7b72val Te6edf3tracerouteHandlerTb4b4b4: Te6edf3TracerouteHandlerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3neighborInfoHandlerTb4b4b4: Te6edf3NeighborInfoHandlerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3radioConfigRepositoryTb4b4b4: Te6edf3RadioConfigRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3messageFilterTb4b4b4: Te6edf3MessageFilterTb4b4b4,

Tff7b72private Tff7b72val Te6edf3storeForwardHandlerTb4b4b4: Te6edf3StoreForwardPacketHandlerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3telemetryHandlerTb4b4b4: Te6edf3TelemetryPacketHandlerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3adminPacketHandlerTb4b4b4: Te6edf3AdminPacketHandlerTb4b4b4,

Tf0883e@NamedTb4b4b4(Ta5d6ff"Ta5d6ffServiceScopeTa5d6ff"Tb4b4b4) Tff7b72private Tff7b72val Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3MeshDataHandler Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3rememberDataType Tff7b72=

Te6edf3setOfTb4b4b4(

Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3PortNumTb4b4b4.Te6edf3ALERT_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3PortNumTb4b4b4.Te6edf3WAYPOINT_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3PortNumTb4b4b4.Te6edf3NODE_STATUS_APPTb4b4b4.Te6edf3valueTb4b4b4,

Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffhandleReceivedDataTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3logUuidTb4b4b4: Tffa657String?Tb4b4b4, Te6edf3logInsertJobTb4b4b4: Te6edf3Job?Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dataPacket Tff7b72= Te6edf3dataMapperTb4b4b4.Te6edf3toDataPacketTb4b4b4(Te6edf3packetTb4b4b4) Tff7b72?: Tff7b72return

Tff7b72val Te6edf3fromUs Tff7b72= Te6edf3myNodeNum Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3from

Te6edf3dataPacketTb4b4b4.Te6edf3status Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3RECEIVED

Tff7b72val Te6edf3shouldBroadcast Tff7b72= Te6edf3handleDataPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3fromUsTb4b4b4, Te6edf3logUuidTb4b4b4, Te6edf3logInsertJobTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3shouldBroadcastTb4b4b4) Tb4b4b4{

Te6edf3serviceBroadcastsTb4b4b4.Te6edf3broadcastReceivedDataTb4b4b4(Te6edf3dataPacketTb4b4b4)

Tb4b4b4}

Te6edf3analyticsTb4b4b4.Te6edf3trackTb4b4b4(Ta5d6ff"Ta5d6ffnum_data_receiveTa5d6ff"Tb4b4b4, Te6edf3DataPairTb4b4b4(Ta5d6ff"Ta5d6ffnum_data_receiveTa5d6ff"Tb4b4b4, T79c0ff1Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleDataPacketTb4b4b4(

Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4,

Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4,

Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3fromUsTb4b4b4: Tffa657BooleanTb4b4b4,

Te6edf3logUuidTb4b4b4: Tffa657String?Tb4b4b4,

Te6edf3logInsertJobTb4b4b4: Te6edf3Job?Tb4b4b4,

Tb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{

Tff7b72var Te6edf3shouldBroadcast Tff7b72= Tff7b72!Te6edf3fromUs

Tff7b72val Te6edf3decoded Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decoded Tff7b72?: Tff7b72return Te6edf3shouldBroadcast

Tff7b72when Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3portnumTb4b4b4) Tb4b4b4{

Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APP Tff7b72-Tff7b72> Te6edf3handleTextMessageTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Te6edf3PortNumTb4b4b4.Te6edf3NODE_STATUS_APP Tff7b72-Tff7b72> Te6edf3handleNodeStatusTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Te6edf3PortNumTb4b4b4.Te6edf3ALERT_APP Tff7b72-Tff7b72> Te6edf3rememberDataPacketTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Te6edf3PortNumTb4b4b4.Te6edf3WAYPOINT_APP Tff7b72-Tff7b72> Te6edf3handleWaypointTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Te6edf3PortNumTb4b4b4.Te6edf3POSITION_APP Tff7b72-Tff7b72> Te6edf3handlePositionTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Te6edf3PortNumTb4b4b4.Te6edf3NODEINFO_APP Tff7b72-Tff7b72> Tff7b72if Tb4b4b4(Tff7b72!Te6edf3fromUsTb4b4b4) Te6edf3handleNodeInfoTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3PortNumTb4b4b4.Te6edf3TELEMETRY_APP Tff7b72-Tff7b72> Te6edf3telemetryHandlerTb4b4b4.Te6edf3handleTelemetryTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tff7b72else Tff7b72-Tff7b72>

Te6edf3shouldBroadcast Tff7b72=

Te6edf3handleSpecializedDataPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3fromUsTb4b4b4, Te6edf3logUuidTb4b4b4, Te6edf3logInsertJobTb4b4b4)

Tb4b4b4}

Tff7b72return Te6edf3shouldBroadcast

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleSpecializedDataPacketTb4b4b4(

Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4,

Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4,

Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3fromUsTb4b4b4: Tffa657BooleanTb4b4b4,

Te6edf3logUuidTb4b4b4: Tffa657String?Tb4b4b4,

Te6edf3logInsertJobTb4b4b4: Te6edf3Job?Tb4b4b4,

Tb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{

Tff7b72var Te6edf3shouldBroadcast Tff7b72= Tff7b72!Te6edf3fromUs

Tff7b72val Te6edf3decoded Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decoded Tff7b72?: Tff7b72return Te6edf3shouldBroadcast

Tff7b72when Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3portnumTb4b4b4) Tb4b4b4{

Te6edf3PortNumTb4b4b4.Te6edf3TRACEROUTE_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3tracerouteHandlerTb4b4b4.Te6edf3handleTracerouteTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3logUuidTb4b4b4, Te6edf3logInsertJobTb4b4b4)

Te6edf3shouldBroadcast Tff7b72= Tff7b72false

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3ROUTING_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3handleRoutingTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4)

Te6edf3shouldBroadcast Tff7b72= Tff7b72true

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3PAXCOUNTER_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3handlePaxCounterTb4b4b4(Te6edf3packetTb4b4b4)

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3STORE_FORWARD_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3storeForwardHandlerTb4b4b4.Te6edf3handleStoreAndForwardTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3STORE_FORWARD_PLUSPLUS_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3storeForwardHandlerTb4b4b4.Te6edf3handleStoreForwardPlusPlusTb4b4b4(Te6edf3packetTb4b4b4)

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3ADMIN_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3adminPacketHandlerTb4b4b4.Te6edf3handleAdminMessageTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3NEIGHBORINFO_APP Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3neighborInfoHandlerTb4b4b4.Te6edf3handleNeighborInfoTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3shouldBroadcast Tff7b72= Tff7b72true

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3ATAK_PLUGINTb4b4b4,

Te6edf3PortNumTb4b4b4.Te6edf3ATAK_FORWARDERTb4b4b4,

Te6edf3PortNumTb4b4b4.Te6edf3PRIVATE_APPTb4b4b4,

Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3shouldBroadcast Tff7b72= Tff7b72true

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3RANGE_TEST_APPTb4b4b4,

Te6edf3PortNumTb4b4b4.Te6edf3DETECTION_SENSOR_APPTb4b4b4,

Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3handleRangeTestTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Te6edf3shouldBroadcast Tff7b72= Tff7b72true

Tb4b4b4}

Tff7b72else Tff7b72-Tff7b72> Tb4b4b4{

T8b949e// By default, if we don't know what it is, we should probably broadcast it

T8b949e// so that external apps can handle it.

Te6edf3shouldBroadcast Tff7b72= Tff7b72true

Tb4b4b4}

Tff7b72return Te6edf3shouldBroadcast

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleRangeTestTb4b4b4(Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3u Tff7b72= Te6edf3dataPacketTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4)

Te6edf3rememberDataPacketTb4b4b4(Te6edf3uTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandlePaxCounterTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3p Tff7b72= Te6edf3PaxcountTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeOrNullTb4b4b4(Te6edf3payloadTb4b4b4, Te6edf3LoggerTb4b4b4) Tff7b72?: Tff7b72return

Te6edf3nodeManagerTb4b4b4.Te6edf3handleReceivedPaxcounterTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4, Te6edf3pTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandlePositionTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3p Tff7b72= Te6edf3PositionTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeOrNullTb4b4b4(Te6edf3payloadTb4b4b4, Te6edf3LoggerTb4b4b4) Tff7b72?: Tff7b72return

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffPosition from Tffd700${Te6edf3packetTb4b4b4.Te6edf3fromTffd700}Ta5d6ff: Tffd700${Te6edf3PositionTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3toOneLinerTb4b4b4(Te6edf3pTb4b4b4)Tffd700}Ta5d6ff" Tb4b4b4}

Te6edf3nodeManagerTb4b4b4.Te6edf3handleReceivedPositionTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3pTb4b4b4, Te6edf3dataPacketTb4b4b4.Te6edf3timeTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleWaypointTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3u Tff7b72= Te6edf3WaypointTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3payloadTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3uTb4b4b4.Te6edf3locked_to Tff7b72!Tff7b72= T79c0ff0 Tff7b72&Tff7b72& Te6edf3uTb4b4b4.Te6edf3locked_to Tff7b72!Tff7b72= Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4) Tff7b72return

Tff7b72val Te6edf3currentSecond Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)

Te6edf3rememberDataPacketTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3updateNotification Tff7b72= Te6edf3uTb4b4b4.Te6edf3expire Tff7b72> Te6edf3currentSecondTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleTextMessageTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3decoded Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decoded Tff7b72?: Tff7b72return

Tff7b72if Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3reply_id Tff7b72!Tff7b72= T79c0ff0 Tff7b72&Tff7b72& Te6edf3decodedTb4b4b4.Te6edf3emoji Tff7b72!Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{

Te6edf3rememberReactionTb4b4b4(Te6edf3packetTb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3rememberDataPacketTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleNodeInfoTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3u Tff7b72=

Te6edf3UserTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3payloadTb4b4b4)

Tb4b4b4.Te6edf3let Tb4b4b4{ Tff7b72if Tb4b4b4(Tffa657itTb4b4b4.Te6edf3is_licensed Tff7b72=Tff7b72= Tff7b72trueTb4b4b4) Tffa657itTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3public_key Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4) Tff7b72else Tffa657it Tb4b4b4}

Tb4b4b4.Te6edf3let Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3via_mqtt Tff7b72=Tff7b72= Tff7b72true Tff7b72&Tff7b72& Tff7b72!Tffa657itTb4b4b4.Te6edf3long_nameTb4b4b4.Te6edf3endsWithTb4b4b4(Ta5d6ff"Ta5d6ff (MQTT)Ta5d6ff"Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tffa657itTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3long_name Tff7b72= Ta5d6ff"Tffd700${Tffa657itTb4b4b4.Te6edf3long_nameTffd700}Ta5d6ff (MQTT)Ta5d6ff"Tb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Tffa657it

Tb4b4b4}

Te6edf3nodeManagerTb4b4b4.Te6edf3handleReceivedUserTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4, Te6edf3uTb4b4b4, Te6edf3packetTb4b4b4.Te6edf3channelTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleNodeStatusTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3s Tff7b72= Te6edf3StatusMessageTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeOrNullTb4b4b4(Te6edf3payloadTb4b4b4, Te6edf3LoggerTb4b4b4) Tff7b72?: Tff7b72return

Te6edf3nodeManagerTb4b4b4.Te6edf3handleReceivedNodeStatusTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4, Te6edf3sTb4b4b4)

Te6edf3rememberDataPacketTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffhandleRoutingTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3payload Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3payload Tff7b72?: Tff7b72return

Tff7b72val Te6edf3r Tff7b72= Te6edf3RoutingTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeOrNullTb4b4b4(Te6edf3payloadTb4b4b4, Te6edf3LoggerTb4b4b4) Tff7b72?: Tff7b72return

Tff7b72if Tb4b4b4(Te6edf3rTb4b4b4.Te6edf3error_reason Tff7b72=Tff7b72= Te6edf3RoutingTb4b4b4.Te6edf3ErrorTb4b4b4.Te6edf3DUTY_CYCLE_LIMITTb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3serviceRepositoryTb4b4b4.Te6edf3setErrorMessageTb4b4b4(Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3error_duty_cycleTb4b4b4)Tb4b4b4, Te6edf3SeverityTb4b4b4.Te6edf3WarnTb4b4b4)

Tb4b4b4}

Te6edf3handleAckNakTb4b4b4(

Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3request_id Tff7b72?: T79c0ff0Tb4b4b4,

Te6edf3nodeManagerTb4b4b4.Te6edf3toNodeIDTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4)Tb4b4b4,

Te6edf3rTb4b4b4.Te6edf3error_reasonTff7b72?.Te6edf3value Tff7b72?: T79c0ff0Tb4b4b4,

Te6edf3dataPacketTb4b4b4.Te6edf3relayNodeTb4b4b4,

Tb4b4b4)

Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3request_idTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3removeResponseTb4b4b4(Tffa657itTb4b4b4, Te6edf3complete Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffCyclomaticComplexMethodTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffhandleAckNakTb4b4b4(Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3fromIdTb4b4b4: Tffa657StringTb4b4b4, Te6edf3routingErrorTb4b4b4: Tffa657IntTb4b4b4, Te6edf3relayNodeTb4b4b4: Tffa657Int?Tb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Tff7b72val Te6edf3isAck Tff7b72= Te6edf3routingError Tff7b72=Tff7b72= Te6edf3RoutingTb4b4b4.Te6edf3ErrorTb4b4b4.Te6edf3NONETb4b4b4.Te6edf3value

Tff7b72val Te6edf3p Tff7b72= Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3getPacketByPacketIdTb4b4b4(Te6edf3requestIdTb4b4b4)

Tff7b72val Te6edf3reaction Tff7b72= Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3getReactionByPacketIdTb4b4b4(Te6edf3requestIdTb4b4b4)

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffMaxLineLengthTa5d6ff"Tb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{

Tff7b72val Te6edf3statusInfo Tff7b72= Ta5d6ff"Ta5d6ffstatus=Tffd700${Te6edf3pTff7b72?.Te6edf3status Tff7b72?: Te6edf3reactionTff7b72?.Te6edf3statusTffd700}Ta5d6ff"

Ta5d6ff"Ta5d6ff[ackNak] req=Tffd700$Te6edf3requestIdTa5d6ff routeErr=Tffd700$Te6edf3routingErrorTa5d6ff isAck=Tffd700$Te6edf3isAckTa5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffpacketId=Tffd700${Te6edf3pTff7b72?.Te6edf3id Tff7b72?: Te6edf3reactionTff7b72?.Te6edf3packetIdTffd700}Ta5d6ff dataId=Tffd700${Te6edf3pTff7b72?.Te6edf3idTffd700}Ta5d6ff Tffd700$Te6edf3statusInfoTa5d6ff"

Tb4b4b4}

Tff7b72val Te6edf3m Tff7b72=

Tff7b72when Tb4b4b4{

Te6edf3isAck Tff7b72&Tff7b72& Tb4b4b4(Te6edf3fromId Tff7b72=Tff7b72= Te6edf3pTff7b72?.Te6edf3to Tff7b72|Tff7b72| Te6edf3fromId Tff7b72=Tff7b72= Te6edf3reactionTff7b72?.Te6edf3toTb4b4b4) Tff7b72-Tff7b72> Te6edf3MessageStatusTb4b4b4.Te6edf3RECEIVED

Te6edf3isAck Tff7b72-Tff7b72> Te6edf3MessageStatusTb4b4b4.Te6edf3DELIVERED

Tff7b72else Tff7b72-Tff7b72> Te6edf3MessageStatusTb4b4b4.Te6edf3ERROR

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3p Tff7b72!Tff7b72= Tff7b72null Tff7b72&Tff7b72& Te6edf3pTb4b4b4.Te6edf3status Tff7b72!Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3RECEIVEDTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3updatedPacket Tff7b72=

Te6edf3pTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3status Tff7b72= Te6edf3mTb4b4b4, Te6edf3relays Tff7b72= Tff7b72if Tb4b4b4(Te6edf3isAckTb4b4b4) Te6edf3pTb4b4b4.Te6edf3relays Tff7b72+ T79c0ff1 Tff7b72else Te6edf3pTb4b4b4.Te6edf3relaysTb4b4b4, Te6edf3relayNode Tff7b72= Te6edf3relayNodeTb4b4b4)

Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3updatedPacketTb4b4b4, Te6edf3routingError Tff7b72= Te6edf3routingErrorTb4b4b4)

Tb4b4b4}

Te6edf3reactionTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3r Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3rTb4b4b4.Te6edf3status Tff7b72!Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3RECEIVEDTb4b4b4) Tb4b4b4{

Tff7b72var Te6edf3updated Tff7b72= Te6edf3rTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3status Tff7b72= Te6edf3mTb4b4b4, Te6edf3routingError Tff7b72= Te6edf3routingErrorTb4b4b4, Te6edf3relayNode Tff7b72= Te6edf3relayNodeTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3isAckTb4b4b4) Tb4b4b4{

Te6edf3updated Tff7b72= Te6edf3updatedTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3relays Tff7b72= Te6edf3updatedTb4b4b4.Te6edf3relays Tff7b72+ T79c0ff1Tb4b4b4)

Tb4b4b4}

Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3updateReactionTb4b4b4(Te6edf3updatedTb4b4b4)

Tb4b4b4}

Te6edf3serviceBroadcastsTb4b4b4.Te6edf3broadcastMessageStatusTb4b4b4(Te6edf3requestIdTb4b4b4, Te6edf3mTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffrememberDataPacketTb4b4b4(Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3updateNotificationTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3dataType Tff7b72!in Te6edf3rememberDataTypeTb4b4b4) Tff7b72return

Tff7b72val Te6edf3fromLocal Tff7b72=

Te6edf3dataPacketTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_LOCAL Tff7b72|Tff7b72| Te6edf3dataPacketTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3nodeNumToDefaultIdTb4b4b4(Te6edf3myNodeNumTb4b4b4)

Tff7b72val Te6edf3toBroadcast Tff7b72= Te6edf3dataPacketTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_BROADCAST

Tff7b72val Te6edf3contactId Tff7b72= Tff7b72if Tb4b4b4(Te6edf3fromLocal Tff7b72|Tff7b72| Te6edf3toBroadcastTb4b4b4) Te6edf3dataPacketTb4b4b4.Te6edf3to Tff7b72else Te6edf3dataPacketTb4b4b4.Te6edf3from

T8b949e// contactKey: unique contact key filter (channel)+(nodeId)

Tff7b72val Te6edf3contactKey Tff7b72= Ta5d6ff"Tffd700${Te6edf3dataPacketTb4b4b4.Te6edf3channelTffd700}Tffd700$Te6edf3contactIdTa5d6ff"

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3apply Tb4b4b4{

T8b949e// Check for duplicates before inserting

Tff7b72val Te6edf3existingPackets Tff7b72= Te6edf3findPacketsWithIdTb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3idTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3existingPacketsTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{

Ta5d6ff"Ta5d6ffSkipping duplicate packet: packetId=Tffd700${Te6edf3dataPacketTb4b4b4.Te6edf3idTffd700}Ta5d6ff from=Tffd700${Te6edf3dataPacketTb4b4b4.Te6edf3fromTffd700}Ta5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffto=Tffd700${Te6edf3dataPacketTb4b4b4.Te6edf3toTffd700}Ta5d6ff contactKey=Tffd700$Te6edf3contactKeyTa5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ff (already have Tffd700${Te6edf3existingPacketsTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff packet(s))Ta5d6ff"

Tb4b4b4}

Tff7b72returnTf0883e@handledLaunch

Tb4b4b4}

T8b949e// Check if message should be filtered

Tff7b72val Te6edf3isFiltered Tff7b72= Te6edf3shouldFilterMessageTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3contactKeyTb4b4b4)

Te6edf3insertTb4b4b4(

Te6edf3dataPacketTb4b4b4,

Te6edf3myNodeNumTb4b4b4,

Te6edf3contactKeyTb4b4b4,

Te6edf3nowMillisTb4b4b4,

Te6edf3read Tff7b72= Te6edf3fromLocal Tff7b72|Tff7b72| Te6edf3isFilteredTb4b4b4,

Te6edf3filtered Tff7b72= Te6edf3isFilteredTb4b4b4,

Tb4b4b4)

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3isFilteredTb4b4b4) Tb4b4b4{

Te6edf3handlePacketNotificationTb4b4b4(Te6edf3dataPacketTb4b4b4, Te6edf3contactKeyTb4b4b4, Te6edf3updateNotificationTb4b4b4)

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffReturnCountTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72suspend Tff7b72fun Te6edf3PacketRepositoryTb4b4b4.Td2a8ffshouldFilterMessageTb4b4b4(Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{

Tff7b72val Te6edf3isIgnored Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyIDTff7b72[Te6edf3dataPacketTb4b4b4.Te6edf3fromTff7b72]Tff7b72?.Te6edf3isIgnored Tff7b72=Tff7b72= Tff7b72true

Tff7b72if Tb4b4b4(Te6edf3isIgnoredTb4b4b4) Tff7b72return Tff7b72true

Tff7b72if Tb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3dataType Tff7b72!Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4) Tff7b72return Tff7b72false

Tff7b72val Te6edf3isFilteringDisabled Tff7b72= Te6edf3getContactSettingsTb4b4b4(Te6edf3contactKeyTb4b4b4)Tb4b4b4.Te6edf3filteringDisabled

Tff7b72return Te6edf3messageFilterTb4b4b4.Te6edf3shouldFilterTb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3textTb4b4b4.Te6edf3orEmptyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3isFilteringDisabledTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffhandlePacketNotificationTb4b4b4(

Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4,

Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3updateNotificationTb4b4b4: Tffa657BooleanTb4b4b4,

Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3conversationMuted Tff7b72= Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3getContactSettingsTb4b4b4(Te6edf3contactKeyTb4b4b4)Tb4b4b4.Te6edf3isMuted

Tff7b72val Te6edf3nodeMuted Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyIDTff7b72[Te6edf3dataPacketTb4b4b4.Te6edf3fromTff7b72]Tff7b72?.Te6edf3isMuted Tff7b72=Tff7b72= Tff7b72true

Tff7b72val Te6edf3isSilent Tff7b72= Te6edf3conversationMuted Tff7b72|Tff7b72| Te6edf3nodeMuted

Tff7b72if Tb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3dataType Tff7b72=Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3ALERT_APPTb4b4b4.Te6edf3value Tff7b72&Tff7b72& Tff7b72!Te6edf3isSilentTb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3notificationManagerTb4b4b4.Te6edf3dispatchTb4b4b4(

Te6edf3NotificationTb4b4b4(

Te6edf3title Tff7b72= Te6edf3getSenderNameTb4b4b4(Te6edf3dataPacketTb4b4b4)Tb4b4b4,

Te6edf3message Tff7b72= Te6edf3dataPacketTb4b4b4.Te6edf3alert Tff7b72?: Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3critical_alertTb4b4b4)Tb4b4b4,

Te6edf3category Tff7b72= Te6edf3NotificationTb4b4b4.Te6edf3CategoryTb4b4b4.Te6edf3AlertTb4b4b4,

Te6edf3contactKey Tff7b72= Te6edf3contactKeyTb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tb4b4b4} Tff7b72else Tff7b72if Tb4b4b4(Te6edf3updateNotification Tff7b72&Tff7b72& Tff7b72!Te6edf3isSilentTb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{ Te6edf3updateNotificationTb4b4b4(Te6edf3contactKeyTb4b4b4, Te6edf3dataPacketTb4b4b4, Te6edf3isSilentTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffgetSenderNameTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4)Tb4b4b4: Tffa657String Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_LOCALTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3myId Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3getMyIdTb4b4b4(Tb4b4b4)

Tff7b72return Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyIDTff7b72[Te6edf3myIdTff7b72]Tff7b72?.Te6edf3userTff7b72?.Te6edf3long_name Tff7b72?: Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3unknown_usernameTb4b4b4)

Tb4b4b4}

Tff7b72return Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyIDTff7b72[Te6edf3packetTb4b4b4.Te6edf3fromTff7b72]Tff7b72?.Te6edf3userTff7b72?.Te6edf3long_name Tff7b72?: Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3unknown_usernameTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffupdateNotificationTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4, Te6edf3dataPacketTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3isSilentTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{

Tff7b72when Tb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3dataTypeTb4b4b4) Tb4b4b4{

Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3value Tff7b72-Tff7b72> Tb4b4b4{

Tff7b72val Te6edf3message Tff7b72= Te6edf3dataPacketTb4b4b4.Te6edf3textTff7b72!!

Tff7b72val Te6edf3channelName Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4) Tb4b4b4{

Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3getOrNullTb4b4b4(Te6edf3dataPacketTb4b4b4.Te6edf3channelTb4b4b4)Tff7b72?.Te6edf3name

Tb4b4b4} Tff7b72else Tb4b4b4{

Tff7b72null

Tb4b4b4}

Te6edf3serviceNotificationsTb4b4b4.Te6edf3updateMessageNotificationTb4b4b4(

Te6edf3contactKeyTb4b4b4,

Te6edf3getSenderNameTb4b4b4(Te6edf3dataPacketTb4b4b4)Tb4b4b4,

Te6edf3messageTb4b4b4,

Te6edf3dataPacketTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4,

Te6edf3channelNameTb4b4b4,

Te6edf3isSilentTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Te6edf3PortNumTb4b4b4.Te6edf3WAYPOINT_APPTb4b4b4.Te6edf3value Tff7b72-Tff7b72> Tb4b4b4{

Tff7b72val Te6edf3message Tff7b72= Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3waypoint_receivedTb4b4b4, Te6edf3dataPacketTb4b4b4.Te6edf3waypointTff7b72!!Tb4b4b4.Te6edf3nameTb4b4b4)

Te6edf3notificationManagerTb4b4b4.Te6edf3dispatchTb4b4b4(

Te6edf3NotificationTb4b4b4(

Te6edf3title Tff7b72= Te6edf3getSenderNameTb4b4b4(Te6edf3dataPacketTb4b4b4)Tb4b4b4,

Te6edf3message Tff7b72= Te6edf3messageTb4b4b4,

Te6edf3category Tff7b72= Te6edf3NotificationTb4b4b4.Te6edf3CategoryTb4b4b4.Te6edf3MessageTb4b4b4,

Te6edf3contactKey Tff7b72= Te6edf3contactKeyTb4b4b4,

Te6edf3isSilent Tff7b72= Te6edf3isSilentTb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72else Tff7b72-Tff7b72> Tff7b72return

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffKotlinConstantConditionsTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffrememberReactionTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4) Tff7b72= Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{

Tff7b72val Te6edf3decoded Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decoded Tff7b72?: Tff7b72returnTf0883e@handledLaunch

Tff7b72val Te6edf3emoji Tff7b72= Te6edf3decodedTb4b4b4.Te6edf3payloadTb4b4b4.Te6edf3toByteArrayTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3decodeToStringTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3fromId Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3toNodeIDTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4)

Tff7b72val Te6edf3fromNode Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTff7b72[Te6edf3packetTb4b4b4.Te6edf3fromTff7b72] Tff7b72?: Te6edf3NodeTb4b4b4(Te6edf3num Tff7b72= Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4)

Tff7b72val Te6edf3toNode Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTff7b72[Te6edf3packetTb4b4b4.Te6edf3toTff7b72] Tff7b72?: Te6edf3NodeTb4b4b4(Te6edf3num Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toTb4b4b4)

Tff7b72val Te6edf3reaction Tff7b72=

Te6edf3ReactionTb4b4b4(

Te6edf3replyId Tff7b72= Te6edf3decodedTb4b4b4.Te6edf3reply_idTb4b4b4,

Te6edf3user Tff7b72= Te6edf3fromNodeTb4b4b4.Te6edf3userTb4b4b4,

Te6edf3emoji Tff7b72= Te6edf3emojiTb4b4b4,

Te6edf3timestamp Tff7b72= Te6edf3nowMillisTb4b4b4,

Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rx_snrTb4b4b4,

Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rx_rssiTb4b4b4,

Te6edf3hopsAway Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72=Tff7b72= T79c0ff0 Tff7b72|Tff7b72| Te6edf3packetTb4b4b4.Te6edf3hop_limit Tff7b72> Te6edf3packetTb4b4b4.Te6edf3hop_startTb4b4b4) Tb4b4b4{

Te6edf3HOPS_AWAY_UNAVAILABLE

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72- Te6edf3packetTb4b4b4.Te6edf3hop_limit

Tb4b4b4}Tb4b4b4,

Te6edf3packetId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4,

Te6edf3status Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3RECEIVEDTb4b4b4,

Te6edf3to Tff7b72= Te6edf3toNodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3idTb4b4b4,

Te6edf3channel Tff7b72= Te6edf3packetTb4b4b4.Te6edf3channelTb4b4b4,

Tb4b4b4)

T8b949e// Check for duplicates before inserting

Tff7b72val Te6edf3existingReactions Tff7b72= Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3findReactionsWithIdTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3existingReactionsTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{

Ta5d6ff"Ta5d6ffSkipping duplicate reaction: packetId=Tffd700${Te6edf3packetTb4b4b4.Te6edf3idTffd700}Ta5d6ff replyId=Tffd700${Te6edf3decodedTb4b4b4.Te6edf3reply_idTffd700}Ta5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6fffrom=Tffd700$Te6edf3fromIdTa5d6ff emoji=Tffd700$Te6edf3emojiTa5d6ff (already have Tffd700${Te6edf3existingReactionsTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff reaction(s))Ta5d6ff"

Tb4b4b4}

Tff7b72returnTf0883e@handledLaunch

Tb4b4b4}

Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3insertReactionTb4b4b4(Te6edf3reactionTb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: T79c0ff0Tb4b4b4)

T8b949e// Find the original packet to get the contactKey

Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3getPacketByPacketIdTb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3reply_idTb4b4b4)Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3originalPacket Tff7b72-Tff7b72>

T8b949e// Skip notification if the original message was filtered

Tff7b72val Te6edf3targetId Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3originalPacketTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_LOCALTb4b4b4) Te6edf3originalPacketTb4b4b4.Te6edf3to Tff7b72else Te6edf3originalPacketTb4b4b4.Te6edf3from

Tff7b72val Te6edf3contactKey Tff7b72= Ta5d6ff"Tffd700${Te6edf3originalPacketTb4b4b4.Te6edf3channelTffd700}Tffd700$Te6edf3targetIdTa5d6ff"

Tff7b72val Te6edf3conversationMuted Tff7b72= Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3getContactSettingsTb4b4b4(Te6edf3contactKeyTb4b4b4)Tb4b4b4.Te6edf3isMuted

Tff7b72val Te6edf3nodeMuted Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyIDTff7b72[Te6edf3fromIdTff7b72]Tff7b72?.Te6edf3isMuted Tff7b72=Tff7b72= Tff7b72true

Tff7b72val Te6edf3isSilent Tff7b72= Te6edf3conversationMuted Tff7b72|Tff7b72| Te6edf3nodeMuted

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3isSilentTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3channelName Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3originalPacketTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4) Tb4b4b4{

Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3channelSetFlow

Tb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Tb4b4b4.Te6edf3settings

Tb4b4b4.Te6edf3getOrNullTb4b4b4(Te6edf3originalPacketTb4b4b4.Te6edf3channelTb4b4b4)

Tff7b72?.Te6edf3name

Tb4b4b4} Tff7b72else Tb4b4b4{

Tff7b72null

Tb4b4b4}

Te6edf3serviceNotificationsTb4b4b4.Te6edf3updateReactionNotificationTb4b4b4(

Te6edf3contactKeyTb4b4b4,

Te6edf3getSenderNameTb4b4b4(Te6edf3dataMapperTb4b4b4.Te6edf3toDataPacketTb4b4b4(Te6edf3packetTb4b4b4)Tff7b72!!Tb4b4b4)Tb4b4b4,

Te6edf3emojiTb4b4b4,

Te6edf3originalPacketTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4,

Te6edf3channelNameTb4b4b4,

Te6edf3isSilentTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72const Tff7b72val Te6edf3HOPS_AWAY_UNAVAILABLE Tff7b72= Tff7b72-T79c0ff1

Tb4b4b4}